//这个文件是主进程入口文件
#include "MsgQueueUtil.h"
#include <pthread.h>
#include <stdio.h>

//线程处理函数 注册广告机
void *recvConfigMsg(void *param)
{
    while (1)
    {
        //初始化消息队列
        int mqId = get_MsgQueue();
        if(mqId==-1)
        {
        printf("mq create fail\n");
        pthread_exit(NULL);
        }
        //接收消息
        Message msg = {
            .type = 1
        };
        int ret = recvMsg(mqId,&msg,MSG_SIZE);
        if(ret == -1)
        {
            printf("recv data fail\n");
            pthread_exit(NULL);
        }
        printf("recv data success type=%ld,text=%s\n",msg.type,msg.text);

        //向网关发起配置请求
    }
}


int main(int argc, char const *argv[])
{
    printf("进入主线程\n");
    //1.接收配置信息,并向网关注册
    pthread_t tid;
    pthread_create(&tid,NULL,recvConfigMsg,NULL);

    //2.发起心跳请求
    while (1)
    {
        //一进来就发起请求
        sleep(5*60);
    }
    return 0;
}
